7ef023d33c6e847f2d1cf5a95a45847b3262e79d,src/test/java/com/couchbase/client/core/config/DefaultMemcachedBucketConfigTest.java,DefaultMemcachedBucketConfigTest,shouldOnlyUseDataNodesForKetama,#,37

Before Change


    @Test
    public void shouldOnlyUseDataNodesForKetama() throws Exception {
        String raw = Resources.read("memcached_mixed_sherlock.json", getClass());
        MemcachedBucketConfig config = JSON_MAPPER.readValue(raw, MemcachedBucketConfig.class);

        assertEquals(4, config.nodes().size());
        for (Map.Entry<Long, NodeInfo> node : config.ketamaNodes().entrySet()) {

After Change


        String raw = Resources.read("memcached_mixed_sherlock.json", getClass());
        InjectableValues inject = new InjectableValues.Std()
            .addValue("env", environment);
        MemcachedBucketConfig config = JSON_MAPPER.readerFor(MemcachedBucketConfig.class).with(inject).readValue(raw);

        assertEquals(4, config.nodes().size());
        for (Map.Entry<Long, NodeInfo> node : config.ketamaNodes().entrySet()) {